# Start on your laptop
from dask.distributed import LocalCluster
# from dask_kubernetes import KubeCluster

import time
if __name__ == '__main__':
    cluster = LocalCluster(
        # processes=False,
        scheduler_port=8000,
        n_workers=2,
        host='10.204.41.211'

    )
    client = cluster.get_client()
    print(client.scheduler_info())
